package kafkaex

import "github.com/IBM/sarama"

type IConsumerGroup interface {
	GetGroupID() string
}

type ConsumerGroup struct {
	groupID string
	group   sarama.ConsumerGroup
}
